import coin.proto.coin_data_replay_pb2 as cdr_pb2
from coin.util.queue.constants import TopicType


topic_to_kafka_topic_map = {
  cdr_pb2.STRATEGY: TopicType.STRAT,
  cdr_pb2.ACCOUNT: TopicType.ACCOUNT,
  cdr_pb2.ACCOUNT_ESTIMATE: TopicType.ACCOUNTESTIMATE,
  cdr_pb2.TICKER: TopicType.TICKER,
  cdr_pb2.TELEMETRY: TopicType.TELEMETRY,
}
